//package com.liwy3.consume;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
///**
// * Copyright © 元气森林（北京）食品科技集团有限公司. All rights reserved.
// *
// * @Description:
// * @author: Crazy4J
// * @date: 2022年04月21日 14:52
// * @version: V1.0
// */
//@Component
//@Slf4j
//public class Consume1 {
//
//
//    @KafkaListener(groupId = "topic-test1-group", topics = "topic-test1",concurrency = "2")
//    public void listen(String input) {
//        if (input.equals("fail")) {
//            throw new RuntimeException("error...");
//        }
//
//        log.info("线程编号:{},input1 value: {}",Thread.currentThread().getId(), input);
//    }
//
//}
